package com.shujia.common

import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment

import scala.io.Source

object FlinkSqlRun {
  def main(args: Array[String]): Unit = {

    //获取FLink Sql环境
    val table: StreamTableEnvironment = FlinkTool.getFlinkTableEnv()

    //获取需要执行sql 文件路径
    if (args.length == 0) {
      println("请指定sql文件路径")
      return
    }

    //sql文件的路径
    val sqlPath: String = args.head

    //通过sql路径读取sql文件的内容
    val sql: String = Source.fromFile(sqlPath).getLines().toList.mkString("\n")

    println("=" * 100)
    println(sql)
    println("=" * 100)

    //执行sql
    table.executeSql(sql)

  }
}
